const mysql = require('mysql');

const pool = mysql.createPool({
    connectionLimit: 5,
    host: '127.0.0.1',
    port: '3306',
    user: 'root',
    password: 'www666888',
    database: 'news-system',
})

//设置一个query函数来执行数据库操作
//sql---使用时传入sql语句
//params---执行sql语句时传入的参数
const query = (sql, params) => {
    return new Promise((resolve, reject) => {
        //从连接池获取一个连接
        pool.getConnection((err, connection) => {
            if (err) {
                reject(err);
            } else {
                //没有失败则connection代表取到的sql连接
                connection.query(sql, params, (err, result) => {
                    //当查询有结果时需要主动释放连接资源
                    connection.release();
                    if (err) {
                        reject(err);
                    } else {
                        resolve(result);
                    }
                })
            }
        })
    })
}

module.exports = query;
